package com.zzq.demo.kafka.mq.listener;

import com.zzq.demo.kafka.dto.DataUpDTO;
import lombok.extern.slf4j.Slf4j;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

/**
 * @ description:
 * @ author: zhaoziqian
 * @ date: 2019/1/7
 */
//@Slf4j
//@Component
//public class CallbackListener {
//
//    @KafkaListener(topics = "kds_test_callback")
//    public void listen(ConsumerRecord<String, DataUpDTO> record) {
//        log.info("【MESSAGE CALLBACK】接收到数据回执信息，分区 ：{} ,消息key : {} ", record.partition(), record.key());
//        // 接收到错误回执
//        DataUpDTO dataUpDTO = record.value();
//        System.out.println(dataUpDTO);
//    }
//}
